CEP，Complex event processing Wiki定义 “Complex event processing, or CEP, is event processing that co ...

JDK安装版本要求8.0以上 tar xf jdk-8u161-linux-x64.tar.gz -C /usr/local/ mv /usr/local/{jdk1.8.0_161,jdk} ...

使用方式如上，核心就是对SourceFunction的实现 FlinkKafkaConsumerBase FlinkKafkaConsumerBase继承RichPa ...

如果要考虑易用性和效率，使用rocksDB来替代普通内存的kv是有必要的 有了rocksdb，可以range查询，可以支持columnfamily，可以各种压缩 但是rocksdb本身是一个库，是 ...

Example Program The following program is a complete, working example of streaming window word count ...

Flink在流上最大的特点，就是引入全局snapshot， CheckpointCoordinator 做snapshot的核心组件为， CheckpointCoordinator ...

参考，Flink - Generating Timestamps / Watermarks watermark，只有在有window的情况下才用到，所以在window operator前加上a ...

Flink 配置文件 对于管理员来说，差不多经常调整的就只有 conf 下的flink-conf.yaml ： 经过初步的调整，大约有以下模块的参数（未优化） ################### ...

维度表，作为数据仓库里面的概念，是维度属性的集合，比如时间维、地点维; 但这里要讨论流计算中的维度表问题， 流计算中维表问题和数据仓库中有所不同，往往是因为通过agent采集到的数据比较有限 ...

SlotSharingGroup 表示不同的task可以共享slot，但是这是soft的约束，即也可以不在一个slot 默认情况下，整个StreamGraph都会用一个默认的“defaul ...